package com.test.consumer.service;

import com.test.consumer.mapper.UserMapper;
import com.test.consumer.model.User;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.concurrent.ConcurrentHashMap;

@Slf4j
@Service
public class UserService {

    @Autowired
    UserMapper userMapper;

    ConcurrentHashMap<String, Integer> hashMap = new ConcurrentHashMap<>();

    public int createUser(User user) {

        log.info("consumer " + user);
        // 测试重新发送
//        Integer num = hashMap.get(user.getPass());
//        if (num != null) {
//            hashMap.put(user.getPass(), ++num);
//            if (num > 3) {
//                System.out.println(num + "_   " + user);
//                return 1;
//            }
//        } else {
//            hashMap.put(user.getPass(), 1);
//        }
//
//        if (user.getName().equals("4")) {
//            return 0;
//        }
//        return 1;
        int count = userMapper.selectByName(user);
        if (count > 0) {
            return 1;
        }
        return userMapper.insert(user);
    }
}
